google.golang.org/grpc/internal/transport.Stream.ctx (field)
25 uses
google.golang.org/grpc/internal/transport (current package)
client_stream.go#L131: case <-s.ctx.Done():
client_stream.go#L134: s.Close(ContextErr(s.ctx.Err()))
handler_server.go#L418: ctx: ctx,
handler_server.go#L430: reader: recvBufferReader{ctx: s.ctx, ctxDone: s.ctx.Done(), recv: &s.buf},
http2_client.go#L510: s.ctx = ctx
http2_client.go#L513: ctx: s.ctx,
http2_client.go#L514: ctxDone: s.ctx.Done(),
http2_client.go#L928: s.statsHandler.HandleRPC(s.ctx, &stats.OutHeader{
http2_client.go#L1289: if d, ok := s.ctx.Deadline(); ok && !d.After(time.Now()) {
http2_client.go#L1643: s.statsHandler.HandleRPC(s.ctx, &stats.InHeader{
http2_client.go#L1650: s.statsHandler.HandleRPC(s.ctx, &stats.InTrailer{
http2_server.go#L530: s.ctx, s.cancel = context.WithTimeout(ctx, timeout)
http2_server.go#L532: s.ctx, s.cancel = context.WithCancel(ctx)
http2_server.go#L537: s.ctx = metadata.NewIncomingContext(s.ctx, mdata)
http2_server.go#L568: if s.ctx, err = t.inTapHandle(s.ctx, &tap.Info{FullMethodName: s.method, Header: mdata}); err != nil {
http2_server.go#L582: if s.ctx.Err() != nil {
http2_server.go#L617: s.ctxDone = s.ctx.Done()
http2_server.go#L621: ctx: s.ctx,
http2_server.go#L1007: return ContextErr(s.ctx.Err())
server_stream.go#L124: s.ctx = ctx
transport.go#L295: ctx context.Context // the associated context of the stream
transport.go#L345: return s.ctx